package com.taotao.netty.handler;

import com.alibaba.fastjson2.JSON;
import com.taotao.netty.Command;
import com.taotao.netty.ImServer;
import com.taotao.netty.domain.Result;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;

/**
 * @className: ConnectionHandler
 * @author: ZhangYuQi
 * @date: 2025/2/26 下午7:45
 * @Version: 1.0
 * @description:
 */


public class ConnectionHandler {

    public static void  execute(ChannelHandlerContext ctx, Command command){
        // 发送连接成功消息
        ctx.channel().writeAndFlush(new TextWebSocketFrame(
            JSON.toJSONString(Result.success("连接成功"))
        ));

        if(ImServer.USERS.containsKey(command.getNickname())){
            ImServer.USERS.remove(command.getNickname());
//            ctx.channel().writeAndFlush(Result.fail("该昵称已存在,注册失败"));
//            ctx.channel().disconnect();
//            return;
        }


        ImServer.USERS.put(command.getNickname(),ctx.channel());

        //ctx.channel().writeAndFlush(Result.success("与服务端建立连接成功"));
        //ImServer.GROUP.writeAndFlush(Result.success("用户("+command.getNickname()+")上线"));
        //ctx.channel().writeAndFlush(Result.success("当前在线用户有:"+ JSON.toJSONString(ImServer.USERS.keySet())));



    }

}
